package Creating_Observables

import (
	"fmt"
	"github.com/reactivex/rxgo/v2"
	"time"
)

// 创建一个定时发布数据的观察集合
func Demo_Interval() {
	observable := rxgo.Interval(rxgo.WithDuration(5 * time.Second))
	go func() {
		for item := range observable.Observe() {
			if item.Error() {
				fmt.Println("订阅 1：", item.E)
			}
			fmt.Println("订阅 1：", item.V)
		}
	}()
	// 订阅 2
	for item := range observable.Observe() {
		if item.Error() {
			fmt.Println("订阅 2：", item.E)
		}
		fmt.Println("订阅 2：", item.V)
	}
}
